package io.mft.datasource.mq.rabbitmq.admin;

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;

import io.mft.datasource.mq.rabbitmq.MqDatasource;

public class AdminConnectionFactory extends CachingConnectionFactory {

	public AdminConnectionFactory(MqDatasource datasource) {
		super();
		this.setAddresses(datasource.getAddresses());
		this.setUsername(datasource.getUsername());
		this.setPassword(datasource.getPassword());
		this.setChannelCacheSize(datasource.getChannel());
	}
}
